#!/bin/bash
mkdir -p /home/hadoop/monitor
aws s3 cp s3://streaming/flink/script/job_monitor.py /home/hadoop/monitor/
/usr/bin/python3 -u /home/hadoop/monitor/job_monitor.py > /home/hadoop/monitor/monitor.log